package com.matrix.activemq.topic;

import java.util.Random;

public class ProducerTest {

    public static void main(String[] args) throws Exception {
        ProducerTool producerTool = new ProducerTool();
        Random random = new Random();
        for (int i = 0; i < 10; i++) {
            Thread.sleep(random.nextInt(10) * 1000);
            producerTool.producerMessage("hello world-----" + i);
            producerTool.close();
        }
    }
}
